

package com.qiyu.mq.core.consumer;

import org.apache.rocketmq.client.consumer.MQConsumer;
import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;

/**
 * @author  idea
 * @version V1.0
 * @date 2020/8/10
 */
public interface ConsumerFactory {

    /**
     * 创建mq的消费者
     *
     * @param messageModel
     * @return
     */
    MQConsumer createConsumer(MessageModel messageModel);
}
